package com.xcc.cloud.stream.source;


import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 自定义mq的source数据源
 */
public interface MqMessageSource {

    String OUT_PUT = "output";
    String OUT_PUT1 = "output1";
    String OUT_PUT2 = "output2";

    @Output(OUT_PUT)
    MessageChannel output();

    @Output(OUT_PUT1)
    MessageChannel output1();

    @Output(OUT_PUT2)
    MessageChannel output2();

}
